// package com.passion.mq.queues.queue1;
//
// import com.passion.mq.annotation.AsyncMQ;
// import com.passion.mq.config.RocketMqConfig;
// import com.passion.mq.context.MqContext;
// import com.passion.mq.queues.AbstractBusinessOperationMq;
// import lombok.extern.slf4j.Slf4j;
// import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
// import org.springframework.stereotype.Component;
//
// /**
//  * 类描述：在对应业务操作时发送消息到MQ的生产者
//  * 系统中对于异步处理的情况，均可以发送消息到MQ，然后再由接收者进行处理
//  * @author ZhuYin
//  * @since 2024年12月31日
//  */
// @AsyncMQ(executor = "asyncLogTaskThreadPool")
// @Slf4j
// @Component
// @ConditionalOnBean(RocketMqConfig.class)
// public class QueueProducer extends AbstractBusinessOperationMq {
//
//     /**
//      * 方法说明：抽象方法1
//      *
//      * @author ZhuYin
//      * @since 2024年12月31日
//      */
//     @Override
//     public void doSomeThing1() {
//         MqContext.mqSender.sendMessage(QueueConfig.topic, "doSomeThing1");
//     }
//
//     /**
//      * 方法说明：抽象方法2
//      *
//      * @author ZhuYin
//      * @since 2024年12月31日
//      */
//     @Override
//     public void doSomeThing2() {
//         MqContext.mqSender.sendMessage(QueueConfig.topic, "doSomeThing1");
//     }
// }
